package cn.edu.flink.scala.tutorial.多流转换

import cn.edu.flink.scala.tutorial.source.ClickSource
import org.apache.flink.streaming.api.scala._

object UnionTest {
  def main(args: Array[String]): Unit = {
    val env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI()

    val stream1 = env.addSource(new ClickSource)

    val newStream = stream1.union(stream1, stream1, stream1)

    newStream.print()

    env.execute("UnionTest")
  }
}
